package historia_clinica.dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import utilitarios.MiConexion;
import historia_clinica.bean.DistritoDTO;
import historia_clinica.interfaces.DistritoDAO;

public class MySqlDistritoDAO implements DistritoDAO{

	@Override
	public List<DistritoDTO> listadoDistrito(String cod_Depa, String cod_Prov) throws Exception {
		
		List<DistritoDTO> distrito = new ArrayList<DistritoDTO>();
		Connection cn = MiConexion.obtenerConexion();
		
		try {

			String sql	=	"select distinct Cod_Distri,Desc_Distri from distrito where Cod_Depa ="+cod_Depa +" and  Cod_Prov =" + cod_Prov;
			System.out.println("SENTENCIA SQL : " + sql);
			
			Statement pstm = cn.createStatement();
			ResultSet rs = pstm.executeQuery(sql);

			while (rs.next()) {
						
				DistritoDTO objDistrito = new DistritoDTO();
			
				objDistrito.setCod_Distri(rs.getString(1));
				objDistrito.setDesc_Distri(rs.getString(2));
										
				distrito.add(objDistrito);
			}
			
			rs.close();
			pstm.close();
			
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			cn.close();
		}

		return distrito;
	}


}
